home *** CD-ROM | disk | FTP | other *** search
/ Amiga Format CD 7 / Amiga Format AFCD07 (Dec 1996, Issue 91).iso / serious / shareware / programming / ixemul-complete / ixemul / library / vfork.c < prev    next >
Encoding:
C/C++ Source or Header  |  1996-08-18  |  22.1 KB  |  753 lines
  1. /*
  2.  *  This file is part of ixemul.library for the Amiga.
  3.  *  Copyright (C) 1991, 1992  Markus M. Wild
  4.  *  Portions Copyright (C) 1994 Rafael W. Luebbert
  5.  *
  6.  *  This library is free software; you can redistribute it and/or
  7.  *  modify it under the terms of the GNU Library General Public
  8.  *  License as published by the Free Software Foundation; either
  9.  *  version 2 of the License, or (at your option) any later version.
  10.  *
  11.  *  This library is distributed in the hope that it will be useful,
  12.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14.  *  Library General Public License for more details.
  15.  *
  16.  *  You should have received a copy of the GNU Library General Public
  17.  *  License along with this library; if not, write to the Free
  18.  *  Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  19.  *
  20.  *  $Id: vfork.c,v 1.9 1994/06/19 15:18:29 rluebbert Exp $
  21.  *
  22.  *  $Log: vfork.c,v $
  23.  *  Revision 1.9  1994/06/19  15:18:29  rluebbert
  24.  *  *** empty log message ***
  25.  *
  26.  *  Revision 1.7  1992/10/20  16:29:49  mwild
  27.  *  allow a vfork'd process to use the parents memory pool. The new function
  28.  *  vfork2() continues to use the old semantics.
  29.  *
  30.  *  Revision 1.6  1992/09/14  01:48:11  mwild
  31.  *  move kmalloc() out of Forbid() (since the allocator is now Semaphore-based).
  32.  *  move errno assignment after sigsetmask (thanks Niklas!)
  33.  *  remove dead code
  34.  *
  35.  *  Revision 1.5  1992/08/09  21:01:43  amiga
  36.  *  change to 2.x header files
  37.  *  duplicate calling stack frame in vfork_resume() instead of just doing rts.
  38.  *  temporary abort calling 1.3 vfork, until that's fixed again (when???).
  39.  *
  40.  *  Revision 1.4  1992/07/04  19:24:12  mwild
  41.  *  get passing of environment right.
  42.  *  change ix_sleep() calls to new semantics.
  43.  *
  44.  * Revision 1.3  1992/05/18  12:26:25  mwild
  45.  * fixed bad typo that didn't close files before sending wait message.
  46.  * Set childs Input()/Output() to NIL:, we only keep the files in our
  47.  * own filetable.
  48.  *
  49.  * Revision 1.2  1992/05/18  01:02:31  mwild
  50.  * add temporary Delay(100) before CloseLibrary() in the child after
  51.  * vfork(), there seem to arrive some late packets (don't know why..)
  52.  * pass NIL: filehandles as Input()/Output() to the child, so that the
  53.  * real I/O-handles only depend on ix-filetable for usage-count
  54.  *
  55.  * Revision 1.1  1992/05/14  19:55:40  mwild
  56.  * Initial revision
  57.  *
  58.  */
  59.  
  60. #define _KERNEL
  61. #include "ixemul.h"
  62. #include "kprintf.h"
  63.  
  64. #include <sys/syscall.h>
  65. #include <sys/resource.h>
  66. #include <sys/wait.h>
  67. #include <stddef.h>
  68. #include <setjmp.h>
  69. #include <string.h>
  70. #include <stdlib.h>
  71.  
  72. #include <utility/tagitem.h>
  73. #include <dos/dostags.h>
  74.  
  75. #include "version.h"
  76.  
  77. void vfork_own_malloc ();
  78. void volatile vfork_longjmp (jmp_buf, int);
  79. void ruadd(struct rusage *ru, struct rusage *ru2);
  80.  
  81. /* having it in a struct makes parameter passing easier */
  82.  
  83. struct reg_parms {
  84.   jmp_buf jb;
  85. };
  86.  
  87. struct vfork_msg {
  88.   struct Message     vm_msg;
  89.   struct Process    *vm_self;    /* for validation purposes */
  90.   struct Process     *vm_pptr;
  91.   struct reg_parms     *vm_regs;    /* parents context to restore */
  92.   int            vm_own_malloc;
  93.   int             vm_rc;        /* 0 if the child started normally, else errno */
  94. };
  95.  
  96. struct death_msg {
  97.   struct MinNode    dm_node;
  98.   struct Process    *dm_child;
  99.   int            dm_pgrp;
  100.   int            dm_status;
  101.   struct rusage        dm_rusage;
  102. };
  103.  
  104. /* this is the new process generated by vfork () ! */
  105. static void
  106. launcher (void)
  107. {
  108.   void *ixb = OpenLibrary ("ixemul.library", IX_VERSION);
  109.   struct Process *me = (struct Process *) FindTask (0);
  110.   struct vfork_msg *vm = NULL;
  111.   int omask;
  112.  
  113.   do
  114.     {
  115.       if (!vm) 
  116.         WaitPort (& me->pr_MsgPort);
  117.       vm = (struct vfork_msg *) GetMsg (&me->pr_MsgPort);
  118.     }
  119.   while (!vm || vm->vm_self != me);
  120.       
  121.  
  122.   if (ixb)
  123.     {
  124.       /* get parents user area */
  125.       volatile struct user *pu = (struct user *) (vm->vm_pptr->pr_Task.tc_TrapData);
  126.       /* `my' user area. This way we don't have to recalculate it too often */
  127.       volatile struct user *mu = &u;
  128.       /* reaping the dup function of execve() ;-)) */
  129.       int fd;
  130.       int a4_size = pu->u_a4_pointers_size * 4;
  131.  
  132.       /* link ourselves into the parents process lists. Guarantee single
  133.        * threaded access to those lists by locking out any other users of
  134.        * the library (nicer than to just call Forbid()) */
  135.       ix_lock_base ();
  136.       
  137.       /* our older sybling is the last recently created child of the parent */
  138.       mu->p_osptr = pu->p_cptr;
  139.       /* we have no younger sybling */
  140.       mu->p_ysptr = 0;
  141.       /* if we have an older sybling, point its `younger sybling' field at us */
  142.       if (mu->p_osptr)
  143.         {
  144.           struct user *ou = (struct user *) (mu->p_osptr->pr_Task.tc_TrapData);
  145.       ou->p_ysptr = me;
  146.     }
  147.       /* set the parents `last recently created child' field at us */
  148.       pu->p_cptr = me;
  149.  
  150.       /* inherit the process group of our parent */
  151.       mu->p_pgrp = pu->p_pgrp;
  152.       mu->p_pptr = vm->vm_pptr;
  153.  
  154.       /* if we got our own malloc list already, it is safe to call malloc here.
  155.          If not, the stuff done here is postponed to either vfork_resume, or
  156.          execve */
  157.       if (vm->vm_own_malloc)
  158.     {
  159.       /* inherit these global variables. */
  160.       mu->u_environ = (char ***) malloc (4);
  161.       * mu->u_environ = dupvec (* pu->u_environ);
  162.       mu->u_errno = (int *) malloc (4);
  163.       *mu->u_errno = 0;
  164.       mu->u_h_errno = (int *) malloc (4);
  165.       *mu->u_h_errno = 0;
  166.     }
  167.       else
  168.     {
  169.       /* borrow the variables of the parent */
  170.       mu->u_environ = pu->u_environ;
  171.       mu->u_errno = pu->u_errno;
  172.       
  173.       /* tell malloc to use the parents malloc lists */
  174.       mu->u_mdp = pu->u_mdp;
  175.     }
  176.  
  177.       
  178.       /* and inherit several other things as well, upto not including u_md */
  179.       bcopy ((void *)&pu->u_a4_pointers_size, (void *)&mu->u_a4_pointers_size,
  180.          offsetof (struct user, u_md) - offsetof (struct user, u_a4_pointers_size));
  181.       bcopy ((char *)pu - a4_size, (char *)mu - a4_size, a4_size);
  182.  
  183.       /* some things have been copied that should be reset */      
  184.       mu->p_flag &= ~(SFREEA4 | STRC);
  185.       mu->p_xstat = 0;
  186.       bzero ((void *)&mu->u_ru, sizeof (struct rusage));
  187.       bzero ((void *)&mu->u_prof, sizeof (struct uprof));
  188.       mu->u_prof_last_pc = 0;
  189.       bzero ((void *)&mu->u_cru, sizeof (struct rusage));
  190.       bzero ((void *)&mu->u_timer[0], sizeof (struct itimerval)); /* just the REAL timer! */
  191.       syscall (SYS_gettimeofday, & mu->u_start, 0);
  192.       omask = vm->vm_rc;    /* signal mask to restore at the end */
  193.  
  194.       /* and adjust the open count of each of the copied filedescriptors */
  195.       for (fd = 0; fd < NOFILE; fd++)
  196.         if (mu->u_ofile[fd])
  197.           mu->u_ofile[fd]->f_count++;
  198.  
  199.       /* also copy u_segs, after all, the child will run initially in the
  200.      same SegList as the parent. */
  201.       mu->u_segs = pu->u_segs;
  202.       mu->u_start_pc = pu->u_start_pc;
  203.       mu->u_end_pc = pu->u_end_pc;
  204.       
  205.       mu->u_is_root = pu->u_is_root;
  206.       mu->u_a4 = pu->u_a4;
  207.  
  208.       /* copying finished, allow other processes to vfork() as well ;-)) */
  209.       ix_unlock_base ();
  210.       
  211.       /* remember the message we have to reply when either _exit() or 
  212.        * execve() is called */
  213.       mu->p_vfork_msg = vm;
  214.       
  215.       vm->vm_rc = 0;
  216.  
  217.       mu->u_save_sp = (void *) get_sp ();
  218.       /* we get here when the user does an _exit() 
  219.        * (so as well after execve() terminates !) */
  220.       if (_setjmp (mu->u_jmp_buf))
  221.         {
  222.       int i;
  223.  
  224.       /* overkill? */
  225.       vfork_own_malloc ();
  226.  
  227.       /* reset `mu' in here, setjmp() might have clobbered it */
  228.       mu = &u;
  229.  
  230.       /* although this is done in CloseLibrary(), files should 
  231.          really be closed *before* a death-message is sent to
  232.          the parent. */
  233.       for (i = 0; i < NOFILE; i++) 
  234.         if (u.u_ofile[i]) syscall (SYS_close, i);
  235.  
  236.       /* free memory (look that most, best all memory is freed here, as
  237.              long as we're not inside Forbid. If memory is freed in CloseLibrary,
  238.          it may potentially have to wait for the memory semaphore in buddy-alloc.c,
  239.          thus breaking the Forbid! */
  240.       all_free ();
  241.  
  242.       KPRINTF (("&errno = %lx, errno = %ld\n", &errno, errno));
  243.  
  244.       /* this whole thing only happens if our parent is still alive ! */
  245.       if (mu->p_pptr && mu->p_pptr != (struct Process *) 1)
  246.         send_death_msg((struct user *)mu);
  247.       else
  248.         {
  249.           Forbid ();
  250.           KPRINTF (("vforked: couldn't send death_msg\n"));
  251.         }
  252.  
  253.       KPRINTF (("vforked: now closing library\n"));
  254.       CloseLibrary (ixb);
  255.  
  256.       KPRINTF (("vforked: falling off the edge of the world.\n"));
  257.       /* just fall off the edge of the world, this is a process */
  258.       return;
  259.         }
  260.  
  261.       syscall (SYS_sigsetmask, omask);
  262.  
  263.       KPRINTF (("vforked: jumping back\n"));
  264.  
  265.       /* jump into nevereverland ;-) */
  266.       vfork_longjmp (vm->vm_regs->jb, 0);
  267.       /* NOTREACHED */
  268.     }
  269.  
  270.   vm->vm_rc = ENOMEM; /* can't imagine any other reason why the OpenLib should fail */
  271.   ReplyMsg ((struct Message *) vm);
  272.   /* fall off the edge of the world ;-) */
  273. }
  274.  
  275. void
  276. send_death_msg(struct user *mu)
  277. {
  278.   struct death_msg *dm = 0;
  279.  
  280.   /* KPRINTF (("vforked: parent alive, zombie-sig = %ld, vfork_msg = $%lx.\n",
  281.          pu->p_zombie_sig, mu->p_vfork_msg));*/
  282.  
  283.   struct user *pu = (struct user *) (mu->p_pptr->pr_Task.tc_TrapData);
  284.  
  285.   /* send the parent a death message with our return code */
  286.   dm = (struct death_msg *) kmalloc (sizeof (struct death_msg));
  287.  
  288.   Forbid ();
  289.   if (dm)
  290.     {
  291.       dm->dm_status = mu->p_xstat;
  292.       dm->dm_rusage = mu->u_ru;
  293.       ruadd (&dm->dm_rusage, (struct rusage *)&mu->u_cru);
  294.       dm->dm_child = (struct Process *) FindTask (0);
  295.       dm->dm_pgrp  = mu->p_pgrp;
  296.       KPRINTF (("vfork-exit: Adding child $%lx to $%lx\n", dm->dm_child, mu->p_pptr));
  297.       AddTail ((struct List *) &pu->p_zombies, (struct Node *) dm);
  298.     }
  299.  
  300.   _psignal ((struct Task *)mu->p_pptr, SIGCHLD);
  301.  
  302.   /* have to wakeup the parent `by hand' to make sure it gets
  303.      out of its sleep, since it might have SIGCHLD masked out or
  304.      ignored at the moment */
  305.   if (pu->p_stat == SSLEEP && pu->p_wchan == (caddr_t) pu)
  306.     ix_wakeup ((u_int)pu);
  307.  
  308.   if (mu->p_vfork_msg)
  309.     ReplyMsg ((struct Message *) mu->p_vfork_msg);
  310.  
  311.   /* this is necessary for process synchronisation, this process
  312.      will be unlinked from the process chain by wait4(), which will
  313.      also take care of reparenting the process if it was PT_ATTACHed
  314.       by a debugger */
  315.   if (dm)
  316.     ix_sleep ((caddr_t)dm, "vfork-dm");
  317. }
  318.  
  319. /* This function is used by vfork_resume and execve. Perhaps it should be made
  320.    externally available? It causes the process to switch to its own malloc
  321.    list, and copies errno and environ into private space. */
  322. void
  323. vfork_own_malloc (void)
  324. {
  325.   /* use volatile here, or the compiler might do wrong `optimization' .. */
  326.   volatile struct user *p = &u;
  327.  
  328.   if (p->u_mdp != &p->u_md)
  329.     {
  330.       char **parent_environ = *p->u_environ;
  331.       
  332.       /* switch to our memory list (which is initialized by OpenLibrary) */
  333.       p->u_mdp = (void *)&p->u_md;
  334.       /* dupvec now uses malloc() on our list */
  335.       p->u_environ = (char ***) malloc (4);
  336.       *p->u_environ = dupvec (parent_environ);
  337.       p->u_errno = (int *) malloc (4);
  338.       *p->u_errno = 0;
  339.       p->u_h_errno = (int *) malloc (4);
  340.       *p->u_h_errno = 0;
  341.     }
  342. }
  343.  
  344.  
  345. asm ("
  346.     .globl _vfork
  347.     .globl _vfork2
  348.     .globl _vfork_resume
  349. _vfork:
  350.     | store a setjmp () compatible frame on the stack to pass to _vfork ()
  351.     lea    sp@(-18*4),sp        | _JBLEN (17) longs on the stack
  352.     pea    sp@
  353.     jbsr    _setjmp
  354.     addqw    #4,sp
  355.     | now patch sp and pc, since they differ
  356.     addl    #20*4,sp@(8)        | account for buffer space
  357.     movel    sp@(18*4),sp@(20)    | insert real PC (return addr on stack)
  358.     | tell _vfork *not* yet to switch to own malloc-list
  359.     pea    0:W
  360.     bsr    __vfork
  361.     lea    sp@(18*4 + 4),sp
  362.     rts
  363.  
  364. _vfork2:
  365.     | this is the vfork used in older versions of the library
  366.     lea    sp@(-18*4),sp        | _JBLEN (17) longs on the stack
  367.     pea    sp@
  368.     jbsr    _setjmp
  369.     addqw    #4,sp
  370.     | now patch sp and pc, since they differ
  371.     addl    #20*4,sp@(8)        | account for buffer space
  372.     movel    sp@(18*4),sp@(20)    | insert real PC (return addr on stack)
  373.     | tell _vfork to have the child run with own malloc-list.
  374.     pea    1:W
  375.     bsr    __vfork
  376.     lea    sp@(18*4 + 4),sp
  377.     rts
  378.  
  379.  
  380.     | the following is longjmp(), with the subtle difference that this
  381.     | thing doesn't insist in returning something non-zero... 
  382. _vfork_longjmp:
  383.     movel    sp@(4),a0    /* save area pointer */
  384.     tstl    a0@(8)        /* ensure non-zero SP */
  385.     jeq    Lbotch        /* oops! */
  386.     movel    sp@(8),d0    /* grab return value */
  387.     moveml    a0@(28),d2-d7/a2-a4/a6    /* restore non-scratch regs */
  388.     movel    a0,sp@-        /* let sigreturn */
  389.     jbsr    _sigreturn    /*   finish for us */
  390.  
  391. Lbotch:
  392.     jsr    _longjmperror
  393.     stop    #0
  394.  
  395. _vfork_resume:
  396.     pea    sp@        | pass the sp containing the return address
  397.     bsr    __vfork_resume
  398.     addqw    #4,sp
  399.     rts
  400. ");
  401.  
  402. /*
  403.  * this is an implementation extension to the `real' vfork2(). Normally you
  404.  * can only cause the parent to resume by calling _exit() or execve() from
  405.  * the child. Since I can't provide a real fork() on the Amiga, this function
  406.  * is a third possibility to make the parent resume. You have then two
  407.  * concurrent processes sharing the same frame and global data... Please be
  408.  * EXTREMELY careful what you may do and what not. vfork2() itself is a hack,
  409.  * this is an even greater one...
  410.  *
  411.  * DO NOT use this function in combination with vfork(), or you'll get a big
  412.  * memory leak. Only use it with vfork2().
  413.  */
  414.  
  415. /*
  416.  * don't make this function static, gcc doesn't notice that it's used from the
  417.  * assembly code above, so make sure it isn't optimized away...
  418.  */
  419. void
  420. _vfork_resume (u_int *copy_from_sp)
  421. {
  422.   struct vfork_msg **vm = &u.p_vfork_msg;
  423.  
  424.   if (*vm)
  425.     {
  426.       u_int *sp = (u_int *)u.u_save_sp;
  427.       u_int *copy_till_sp = (u_int *)get_sp ();
  428.  
  429.       /* be sure to switch to our memory list */
  430.       vfork_own_malloc ();
  431.  
  432.       /* copy the stack frame */
  433.       copy_from_sp++;
  434.       do
  435.     *--sp = *--copy_from_sp;
  436.       while (copy_from_sp > copy_till_sp);
  437.  
  438.       set_sp ((u_int) sp);
  439.  
  440.       ReplyMsg ((struct Message *) *vm);
  441.       *vm = 0;
  442.     }
  443. }
  444.  
  445. #define STACKNAME ("IXSTACK")    /* Environment variable for stack size */
  446. #define STACKSIZE (16384)    /* Minimum stack size to use */
  447.  
  448. static int get_stack_size(struct Process *proc)
  449. {
  450.   struct CommandLineInterface *CLI;
  451.   int stack_size;
  452.   char *tmp;
  453.  
  454.   CLI = BTOCPTR (proc->pr_CLI);
  455.   if ((tmp = getenv (STACKNAME)))
  456.     stack_size = atoi (tmp);
  457.   else
  458.     stack_size = CLI ? CLI->cli_DefaultStack * 4 : proc->pr_StackSize;
  459.   if (stack_size < STACKSIZE)
  460.     return STACKSIZE;
  461.   return stack_size;
  462. }
  463.  
  464. /*
  465.  * don't make this function static, gcc doesn't notice that it's used from the
  466.  * assembly code above, so make sure it isn't optimized away...
  467.  */
  468. int
  469. _vfork (int own_malloc, struct reg_parms rp)
  470. {
  471.   struct Process *me = (struct Process *) FindTask(0);
  472.   struct CommandLineInterface *CLI = (void *)(me->pr_CLI);
  473.   u_int stack_size = get_stack_size(me);
  474.   /* those *have* to be in registers to survive the stack deallocation */
  475.   register struct vfork_msg *vm asm ("a2");
  476.   register int omask asm ("d2");
  477.   register struct Process *child asm ("a3");
  478.   struct TagItem tags [] = {
  479.     { NP_Entry, (ULONG) launcher, },
  480.     { NP_Cli, (ULONG) (CLI ? -1 : 0), },    /* same thing we are */
  481.     { NP_Name, (ULONG) "vfork()'d process", },    /* to be overridden by execve() */
  482.     { NP_StackSize, stack_size, },        /* same size we use */
  483.     { TAG_END, 0, }
  484.   };
  485.   KPRINTF (("vfork: creating child with stacksize = $%lx[$%lx,$%lx]\n", stack_size, tags[3]));
  486.   vm = (struct vfork_msg *) kmalloc (sizeof (struct vfork_msg));
  487.   if (! vm)
  488.     {
  489.       errno = ENOMEM;
  490.       KPRINTF (("&errno = %lx, errno = %ld\n", &errno, errno));
  491.       return -1;
  492.     }
  493.  
  494.   vm->vm_msg.mn_ReplyPort = u.u_sync_mp;
  495.   vm->vm_msg.mn_Node.ln_Type = NT_MESSAGE;
  496.   vm->vm_msg.mn_Length = sizeof (struct vfork_msg);
  497.   vm->vm_pptr = me;
  498.   vm->vm_own_malloc = own_malloc;
  499.   vm->vm_regs = & rp;
  500.  
  501.   /* we have to block all signals as long as the child uses our resources.
  502.    * but since the child needs to start with the signal mask BEFORE this
  503.    * general blocking, we have to pass it the old signal mask. This is a
  504.    * way to do it */
  505.   vm->vm_rc   = 
  506.   omask      = syscall (SYS_sigsetmask, ~0);
  507.  
  508.   /* save the passed frame in our user structure, since the child will
  509.      deallocate it from the stack when it `returns' to user code */
  510.   bcopy (&rp, &u.u_vfork_frame, sizeof (rp));
  511.  
  512.   KPRINTF (("vfork: creating child with stacksize = $%lx[$%lx,$%lx]\n", stack_size, tags[3]));
  513.   child = CreateNewProc (tags);
  514.  
  515.  
  516.   if (! child)
  517.     {
  518.       /* do I have to close input/output here? Or does the startup close
  519.          them no matter whether it succeeds or not ? */
  520.       kfree (vm);
  521.       syscall (SYS_sigsetmask, omask);
  522.       errno = EPROCLIM;
  523.       KPRINTF (("&errno = %lx, errno = %ld\n", &errno, errno));
  524.       return -1;
  525.     }
  526.  
  527.   /* As soon as this message is dispatched, the child will `return' and 
  528.      deallocate the stack we're running on. So afterwards, *only* use
  529.      register variables and then longjmp () back.
  530.      Since we don't have a stack until after the longjmp(), temporarily
  531.      switch to our mini-stack */
  532.   set_sp ((u_int) &u.u_mini_stack[sizeof (u.u_mini_stack) / sizeof (long)]);
  533.  
  534.   vm->vm_self = child;
  535.   PutMsg (&child->pr_MsgPort, (struct Message *) vm);
  536.   /* wait until the child does execve() or _exit() */
  537.   WaitPort (u.u_sync_mp);
  538.   GetMsg (u.u_sync_mp);
  539.   syscall (SYS_sigsetmask, omask);
  540.  
  541.   if (vm->vm_rc)
  542.     {
  543.       errno = (int) vm->vm_rc;
  544.       KPRINTF (("&errno = %lx, errno = %ld\n", &errno, errno));
  545.       child = (struct Process *) -1;
  546.     }
  547.       
  548.   /* this is the parent return, so we pass the id of the new child */
  549.   kfree (vm);
  550.   /* could use longjmp() here, but since we already *have* the local one.. */
  551.   vfork_longjmp (u.u_vfork_frame, (int) child);
  552.   return 0;  /* not reached */
  553. }
  554.  
  555. void ruadd(struct rusage *ru, struct rusage *ru2)
  556. {
  557.     register long *ip, *ip2;
  558.     register int i;
  559.  
  560.     timevaladd(&ru->ru_utime, &ru2->ru_utime);
  561.     timevaladd(&ru->ru_stime, &ru2->ru_stime);
  562.     if (ru->ru_maxrss < ru2->ru_maxrss)
  563.         ru->ru_maxrss = ru2->ru_maxrss;
  564.     ip = &ru->ru_first; ip2 = &ru2->ru_first;
  565.     for (i = &ru->ru_last - &ru->ru_first; i > 0; i--)
  566.         *ip++ += *ip2++;
  567. }
  568.  
  569. /*
  570.  * make process 'parent' the new parent of process 'child'.
  571.  */
  572. void
  573. proc_reparent(struct Process *child, struct Process *parent)
  574. {
  575.     register struct Process *o;
  576.     register struct Process *y;
  577.     struct user *cu = getuser(child);
  578.     struct user *pu = (parent != (struct Process *)1 ? getuser(parent) : 0);
  579.  
  580.     if (cu->p_pptr == parent)
  581.       return;
  582.  
  583.     /* fix up the child linkage for the old parent */
  584.     o = cu->p_osptr;
  585.     y = cu->p_ysptr;
  586.     if (y)
  587.       getuser(y)->p_osptr = o;
  588.     if (o)
  589.       getuser(o)->p_ysptr = y;
  590.     if (cu->p_pptr && cu->p_pptr != (struct Process *)1)
  591.       if (getuser(cu->p_pptr)->p_cptr == child)
  592.         getuser(cu->p_pptr)->p_cptr = o;
  593.  
  594.         if (pu)
  595.           {
  596.         /* fix up child linkage for new parent, if there is one */
  597.         o = pu->p_cptr;
  598.         if (o)
  599.           getuser(o)->p_ysptr = child;
  600.         cu->p_osptr = o;
  601.         cu->p_ysptr = NULL;
  602.         pu->p_cptr = child;
  603.         cu->p_pptr = parent;
  604.       }
  605. }
  606.  
  607. /* This function is in desperate need of redesign !!!! */
  608.  
  609. int
  610. wait4 (int pid, int *status, int options, struct rusage *rusage)
  611. {
  612.   struct Process * me = (struct Process *) FindTask (0);
  613.   struct user * mu = (struct user *) me->pr_Task.tc_TrapData;
  614.  
  615.   for (;;)
  616.     {
  617.       int err = 0;
  618.       struct death_msg *dm, *ndm;
  619.       int got_node;
  620.  
  621.       got_node = 0;
  622.       Forbid ();
  623.       
  624.       for (dm  = (struct death_msg *) mu->p_zombies.mlh_Head;
  625.          (ndm = (struct death_msg *) dm->dm_node.mln_Succ);
  626.          dm  = ndm)
  627.       if (pid == -1 ||
  628.           (pid == 0 && dm->dm_pgrp == mu->p_pgrp) ||
  629.         (pid < -1 && dm->dm_pgrp == - pid) ||
  630.         (pid == (int) dm->dm_child))
  631.       {
  632.         got_node = 1;
  633.         break;
  634.       }
  635.  
  636.       if (!got_node && !mu->p_cptr)
  637.     err = ECHILD;
  638.  
  639.       if (got_node)
  640.     /* Handle exited children first.  */
  641.         {
  642.       struct Process *child = dm->dm_child;
  643.       struct user *cu = getuser(child);
  644.       struct Task *t;
  645.  
  646.       /*
  647.        * If we got the child through a ptrace 'attach',
  648.        * we need to give it back to the old parent.
  649.        */
  650.       if (cu->p_opptr && (t = pfind((pid_t)cu->p_opptr)))
  651.         {
  652.           proc_reparent(child, (struct Process *)t);
  653.           cu->p_opptr = 0;
  654.           _psignal(t, SIGCHLD);
  655.           ix_wakeup((u_int)t);
  656.           Permit();
  657.           return (int)child;
  658.         }
  659.       KPRINTF (("wait4: unlinking child $%lx\n", dm->dm_child));
  660.       Remove ((struct Node *) dm);
  661.       
  662.       if (cu->p_ysptr)
  663.         getuser(cu->p_ysptr)->p_osptr = cu->p_osptr;
  664.  
  665.       if (cu->p_osptr)
  666.         getuser(cu->p_osptr)->p_ysptr = cu->p_ysptr;
  667.  
  668.           if (cu->p_pptr && cu->p_pptr != (struct Process *)1)
  669.         if (getuser(cu->p_pptr)->p_cptr == child)
  670.           getuser(cu->p_pptr)->p_cptr = cu->p_osptr;
  671.  
  672.       ix_wakeup ((u_int)dm);
  673.       Permit ();
  674.  
  675.           if (status)
  676.           {
  677.             *status = dm->dm_status;
  678.           }  
  679.           if (rusage)
  680.             *rusage = dm->dm_rusage;
  681.  
  682.       kfree (dm);
  683.  
  684.           return (int) child;
  685.     }
  686.       else
  687.     /* No child processes have died for now.
  688.        Do we have a traced child process to handle?  */
  689.     {
  690.       struct Process *p;
  691.       struct user *pu;
  692.  
  693.       KPRINTF(("wait4: checking traced children, pid=%lx, mu->p_cptr=%lx\n",
  694.            pid, mu->p_cptr));
  695.  
  696.       for (p = mu->p_cptr;
  697.            p && getuser(p);
  698.            p = getuser(p)->p_osptr)
  699.         {
  700.           KPRINTF(("wait4: checking pid p=%lx\n", p));
  701.           if ((pu = getuser(p)))
  702.             if (pid == -1
  703.             || ((int) p) == pid
  704.             || pu->p_pgrp == -pid
  705.             || (pid == 0
  706.                 && mu->p_pgrp == pu->p_pgrp))
  707.           {        
  708.             KPRINTF(("wait4: pu->p_stat=%lx, pu->flag=%lx\n",
  709.                 pu->p_stat, pu->p_flag));
  710.             if (pu->p_stat == SSTOP
  711.                 && (pu->p_flag & SWTED) == 0
  712.                 && (pu->p_flag & STRC || options & WUNTRACED))
  713.               {
  714.                 KPRINTF(("wait4: SSTOPed; p_xstat=0x%lx, W_STOPCODEd=0x%lx\n",
  715.                 pu->p_xstat, W_STOPCODE (pu->p_xstat)));
  716.                 pu->p_flag |= SWTED;
  717.                 if (status)
  718.                   {
  719.                 *status = W_STOPCODE (pu->p_xstat);
  720.                     KPRINTF(("wait4: status was set to %ld\n", *status));
  721.                   }
  722.                 Permit ();
  723.                 return (int)p;
  724.               }
  725.           }
  726.         }
  727.     }
  728.  
  729.       if (!got_node && err)
  730.     {
  731.       Permit ();
  732.       errno = err;
  733.       KPRINTF (("&errno = %lx, errno = %ld\n", &errno, errno));
  734.       return -1;
  735.     }
  736.  
  737.       if (options & WNOHANG)
  738.     {
  739.       Permit ();
  740.       return 0;
  741.     }
  742.  
  743.       KPRINTF (("wait4: waiting for SIGCHLD\n"));
  744.       ix_sleep ((caddr_t)mu, "wait4");
  745.       if (mu->p_sig)
  746.     err = EINTR;
  747.  
  748.       Permit ();
  749.       if (CURSIG (mu))
  750.         setrun ((struct Task *)me);
  751.     }
  752. }
  753.